//package com.test;
//
//
//import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
///**
// * Copyright
// *
// * @Author WuHuang
// * @Date 2023/3/31
// */
//public interface KafkaCustomConfigHandler {
//
//    /**
//     * 返回kafka自定义配置
//     * @param factory
//     * @return
//     */
//    ConcurrentKafkaListenerContainerFactory<String, KafkaMetaMessage> getCustomContainerFactory(
//            ConcurrentKafkaListenerContainerFactory<String, KafkaMetaMessage> factory
//    );
//
//
//}
